package com.zhl.spark.core.simple

import java.io.ObjectOutputStream
import java.net.Socket

/**
 * @program: demos
 * @description: ${description}
 * @author: 刘振华
 * @create: 2020-11-30 16:23
 **/
object SimpleDriver {

    def main(args: Array[String]): Unit = {
        val socket = new Socket("localhost", 19999)

        val out = socket.getOutputStream()

        val objOut = new ObjectOutputStream(out)

        val task = new SimpleTask()

        objOut.writeObject(task)

        objOut.flush()

        objOut.close()

        socket.close()
    }
}
